import 'dart:async';

///
/// 称重数据流
/// 默认监听的usb或者网络数据发包不一定是同步的如果处理不及时就会导致协议缓冲区数据混乱
/// 因此数据处理需要严格依赖顺序所以需要使用同步流保证异步处理也串行处理
///
class WeightStream {
  final StreamController<int> _controller = StreamController<int>(sync: true);

  push(int data){
    _controller.add(data);
  }

  Stream<int> get stream => _controller.stream;

  void dispose() {
    _controller.close();
  }

}
